package com.lzwk.app.function;

import org.apache.flink.table.functions.ScalarFunction;

/**
 * @Author: CC
 * @Date: 2022/1/5 21:07
 */
public class ToInt extends ScalarFunction {
    public int eval(String s) {
        if(s.matches("[0-9]+")){
            return Integer.parseInt(s);
        }
        return -1;
    }
}


//public class ToInt<T> extends ScalarFunction {
//    public int eval(T s) {
//        if(s instanceof String){
//            String stringS = (String) s;
//            if(stringS.matches("[0-9]+")){
//                System.out.println(s);
//                return Integer.parseInt(stringS);
//            }
//        }
//        return -1;
//    }
//}




